package com.df.base.other;

import org.apache.dubbo.common.stream.StreamObserver;

public interface IGateWayStreamInterface {

    /**
     * 双向通信，
     * 在客户端端，参数为响应，返回值为请求，请求对象发送数据，响应对象接收数据
     *
     * @param replyObserver
     * @return
     */
    StreamObserver<Object> message(StreamObserver<Object> replyObserver);
}
